package cn.me.alphamq.common.util;

/**
 * topic 名称的工具类
 *
 * @author f
 */
public class TopicNameUtil {

    /**
     * 获取重试队列的 topic
     *
     * @param consumerGroup 当前消费者的消费者组名
     * @return 重试队列的 topic
     */
    public static String getRetryTopicName(String consumerGroup) {
        return "retry%" + consumerGroup;
    }

    /**
     * 判断一个 topic 是不是重试队列的 topic
     * <p>
     * 其实就是判断这个 topic 是否以 "retry%" 开头
     *
     * @param topicName 待判断的 topic
     * @return 判断一个 topic 是不是重试队列的 topic
     */
    public static boolean isRetryTopicName(String topicName) {
        return topicName.startsWith("retry%");
    }
}
